package com.xb.system.constants;

import com.xb.model.domain.UsersInfoV1;

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.atomic.AtomicBoolean;

/**
 * @author lzy
 * @create 2024/11/4 16:55
 */
public class BatchTxtConstantsV1 {
    public static final BlockingQueue<UsersInfoV1> QUEUE = new LinkedBlockingQueue<>(20000);
    public static final AtomicBoolean SIGNAL_COMPLETION = new AtomicBoolean(false);
}
